# coding=utf-8

import pika

# 使用的第一步是创建连接并打开一个 Channel
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

# 接着应该声明一个 Exchange，因为这里是一个简单的示例
# 我们使用默认的 Exchange，所以不用申明
# 使用默认的 Exchange 时，不需要执行绑定步骤
# 此时 routing_key 即为 queue 的名字
# 消息会被路由到与 routing_key 名字相同的 queue 中

# 下一步是声明一个 Queue，这里声明了一个名为 hello 的 Queue
channel.queue_declare(queue='hello')

# 接下来就是发布消息
channel.basic_publish(exchange='',
                      routing_key='hello',
                      body='Hello World!')

print " [x] Sent 'Hello World!'"
connection.close()
